package com.deep.stream.consumer.receiver;

import org.springframework.cloud.stream.annotation.Input;
import org.springframework.messaging.SubscribableChannel;

/**
 * @author deeprado
 */
public interface MsgClient {

    String INPUT1 = "input1";

    String INPUT2 = "input2";


    @Input(MsgClient.INPUT1)
    SubscribableChannel input1();

    @Input(MsgClient.INPUT2)
    SubscribableChannel input2();
}
